package com.hrzyit.base.rx

import com.hrzyit.base.presenter.view.BaseView
import io.reactivex.subscribers.DisposableSubscriber
//import rx.Subscriber

/**
 * Rx 订阅默认实现类
 * @author YangWei
 * @date 2019/3/21
 */
open class BaseSubscriber<T>(private var baseView: BaseView) : DisposableSubscriber<T>() {
    override fun onComplete() {
        // 当完成时执行
        // 关闭进度弹窗
        baseView.hideLoading()
    }

    override fun onNext(t: T) {
        //
    }

//    override fun onCompleted() {
//        // 当完成时执行
//        // 关闭进度弹窗
//        baseView.hideLoading()
//    }

    override fun onError(e: Throwable?) {
        // 当错误时执行
        baseView.hideLoading()
        if (e is BaseException) {
            baseView.onError(e.msg)
        }
    }

}